package com.jumei.flume.processor;

import com.jumei.flume.bo.SensorMessage;

import java.util.List;

/**
 * 神策消息预处理
 *
 * @author yihongx
 */
public interface ExternalProcessor {

    List<SensorMessage> process(List<SensorMessage> records, ProcessorContext context) throws Exception;

    void process(SensorMessage record, ProcessorContext context) throws Exception;

    public void start();

    public void stop();
}
